package com.itheima.d03_interface_olp;

import java.sql.*;

/**
 * 目标：了解JDBC编码流程（实际开发不会使用底层JDBC）
 */
public class Test1 {

    public static void main(String[] args) throws SQLException {

    }

    private static void testQuery() throws SQLException {
        //0.准备工作
        //0.1下载mysql数据库厂商提供驱动包（真正和mysql连接的工具）
        //0.2拷贝驱动包到当前项目中
        //0.3导入驱动包:add  as  library

        //--------------------------------------------------

        //1.需求：添加一条部门信息到部门表
        //1.1 获取数据库连接对象                            数据库连接协议   机器地址   mysql软件  数据库名称
        Connection conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/mysql_db03","root","1234");

        //1.2 编写SQL语句
        String sql = "select * from tb_dept;";

        //1.3 发送SQL语句
        Statement sendSqlObj = conn.createStatement();
        ResultSet resultSet = sendSqlObj.executeQuery(sql);

        //1.4 打印处理结果
        while(resultSet.next()){
            System.out.println(resultSet.getInt("id"));
            System.out.println(resultSet.getString("name"));
            System.out.println(resultSet.getDate("create_time"));
            System.out.println(resultSet.getDate("update_time"));
            System.out.println("--------------------------------");
        }
    }

    private static void testUpdate() throws SQLException {
        //0.准备工作
        //0.1下载mysql数据库厂商提供驱动包（真正和mysql连接的工具）
        //0.2拷贝驱动包到当前项目中
        //0.3导入驱动包:add  as  library

        //--------------------------------------------------

        //1.需求：添加一条部门信息到部门表
        //1.1 获取数据库连接对象                            数据库连接协议   机器地址   mysql软件  数据库名称
        Connection conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/mysql_db03","root","1234");

        //1.2 编写SQL语句
        //String sql = "insert into tb_dept (id, name, create_time, update_time) values (null,'坤坤部',now(),now());";
        //String sql = "delete from tb_dept where id = 5;";
        String sql = "update tb_dept set name = '学工二部' where id = 1 ;";

        //1.3 发送SQL语句
        Statement sendSqlObj = conn.createStatement();
        int rs = sendSqlObj.executeUpdate(sql);

        //1.4 打印处理结果
        System.out.println("执行完SQL语句，mysql返回受影响的行数："+rs);
    }

}
